package com.wudl.flink.stream.tablesql

import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.apache.flink.table.api.EnvironmentSettings
import org.apache.flink.table.api.scala.StreamTableEnvironment


object CreateTableEnvironment {
  def main(args: Array[String]): Unit = {
    val streamEvn: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
    val settings: EnvironmentSettings = EnvironmentSettings.newInstance().useOldPlanner().inStreamingMode().build()
    val tableEvn: StreamTableEnvironment = StreamTableEnvironment.create(streamEvn, settings)
  }

}
